package com.heima.comment.listener;

import org.apache.kafka.streams.kstream.KStream;
import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;

public interface ICommentRepayProcessor {

    @Input("comment_repay_score_topic")
    KStream<String, String> input();
    @Output("comment_repay_result_topic")
    KStream<String, String> output();
}
